package com.sdg.server.service;

public class Constant {

    //monogo库名称
    public static String MONGODB_DATABASE = "recom3";
    /*这个是自己手动昂在mongo中进行创建的*/
    public static String MONGODB_USER_COLLECTION = "User";
    //用户的推荐矩阵`
    public static String MONGODB_USER_RECS_COLLECTION = "UserRecs";
    //电影数据表名
    public static String MONGODB_MOVIE_COLLECTION = "Movie";
    //电影相似度矩阵
    public static String MONGODB_MOVIE_RECS_COLLECTION = "MoviesRecs";

    //实时推荐电影表
    //public static String MONGODB_STREAM_RECS_COLLECTION = "StreamRecs";
    public static String MONGODB_STREAM_RECS_COLLECTION = "StreamRecs";

    //种类topN的电影
    public static String MONGODB_GENRES_TOP_MOVIES_COLLECTION = "GenresTopMovies";
    //电影的平均分表名
    public static String MONGODB_AVERAGE_MOVIES_SCORE_COLLECTION = "AverageMoviesScore";

    //最近优质电影矩阵
    public static String MONGODB_RATE_MORE_MOVIES_RECENTLY_COLLECTION = "RateMoreMoviesRecently";
    //优质电影矩阵
    public static String MONGODB_RATE_MORE_MOVIES_COLLECTION = "RateMoreMovies";

    //电影评分表名 [ ]
    public static String MONGODB_RATING_COLLECTION = "Rating";
    //电影标签的表名
    public static String MONGODB_TAG_COLLECTION = "Tag";

    //es 中的索引名称
    public static String ES_INDEX = "recom3";
    //es集群的名称
    public static String ES_CLUSTER_NAME = "my-es";
    //ES 中的电影数据集
    public static String ES_MOVIE_TYPE = "Movie";
    //9200 es和外部通信的端口
    public static String ES_HTTPHOSTS = "vm2:9200";
    //9300 es节点之间同行的端口
    public static String ES_TRANSPORTHOSTS = "vm2:9300";
    //redis
    public static final int USER_RATING_QUEUE_SIZE = 20;

    //Driver class
    public static final String MONGO_DRVIVE_CLASS = "com.mongodb.spark.sql";
    public static final String ES_DRVIVE_CLASS = "com.elasticsearch.spark.sql";
    //url
    public static final String MONGO_URI = "mongodb://vm2:27017/recom3";
    //kafka
    public static final String KAFKA_INPUT_TOPIC = "mdj";
    public static final String KAFKA_OUTPUT_TOPIC = "mdj";
    public static final String KAFKA_BOOTSTRAP_SERVERS = "vm0:9092,vm1:9092,vm2:9092";
    public static final String ZOOKEEPERS_SERVERS = "vm0:2181,vm1:2181,vm2:2181";
    //kafka的标识
    public static final String APPLICATION_ID_CONFIG = "logProcesser";
    //推荐最大的数量
    public static final int USER_MAX_RECOMMENDATION = 20;
    //
    public static int REDIS_MOVIE_RATING_QUEUE_SIZE = 40;
}
